const mysql = require('mysql');
const config = require('../config')


const db = {
  connectionLimit: 10,
  ...config[config.mode].sql
}

module.exports = function(sql, params) {
  return new Promise((resolve, reject) => {
    // 一、新建一个连接池
    let pool = mysql.createPool(db)
    // 二、连接
    pool.getConnection((error, connection) => {
      // 三、使用sql语句操作
      connection.query(sql, params, (err, results, fields) => {
        if (err) {
          reject(err)
        } else {
          resolve(results)
        }
        // 四、释放连接池
        connection.release()
      })
    })
    
  })
}